package com.ylkj.bus.dispatcher;

import com.hwl.common.CustomSerializable;
import com.ylkj.bus.MessageContent;
import org.apache.flink.streaming.api.datastream.DataStream;

/**
 * @Author: wengzx
 * @Date: 2025/3/28
 * @Desc:
 */
public interface IStreamHandler extends CustomSerializable {
    void handle(DataStream<MessageContent> stream);
}
